package com.xzy.springboot;


import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class Stream_8802 {
    public static void main(String[] args) {
        SpringApplication.run(Stream_8802.class,args);
    }

    /*stream是有关mq的技术栈(主要是为了规避不同mq的底层差异,使用统一api完成消息队列,类似数据库连接池)*/

    /*使用步骤(消息消费者)
    * 1.在需要接收消息的类中开启注解@EnableBinding(Sink.class)
    *      sink为 org.springframework.cloud.stream.messaging.Sink;包下
    * 2.在方法上开启监听@StreamListener(Sink.INPUT)
    * 3.将所需消息作为参数写进方法头,消息类型为Message<T>泛型为消息数据类型
            org.springframework.messaging.Message;
    * 4.message.getPayload()接收数据*/
}
